ca6da0b0e397f22a1d730bffc0cc252a7513daaf,cdap-watchdog/src/main/java/co/cask/cdap/metrics/collect/AggregatedMetricsCollectionService.java,AggregatedMetricsCollectionService,runOneIteration,#,104

Before Change


    final long timestamp = TimeUnit.SECONDS.convert(System.currentTimeMillis(), TimeUnit.MILLISECONDS);
    LOG.trace("Start log collection for timestamp {}", timestamp);

    final MetricsCollectorIterator metricsItor = new MetricsCollectorIterator(getMetrics(timestamp));
    publishMetrics(timestamp, metricsItor);
  }

After Change


    final long timestamp = TimeUnit.SECONDS.convert(System.currentTimeMillis(), TimeUnit.MILLISECONDS);
    LOG.trace("Start log collection for timestamp {}", timestamp);

    publishMetrics(timestamp, getMetrics(timestamp));
  }

  private void publishMetrics(long timestamp, Iterator<MetricValues> metrics) {